package ioc

import (
	"go.uber.org/zap"
	rabbitmq "mts/user_srv/utils/rabbitmq"
)

func InitRabbiMQ() (*rabbitmq.RabbitMQ, error) {
	mq, err := rabbitmq.NewRabbitMQ()
	if err != nil {
		zap.S().Errorf("初始化rabbitMQ失败:%s", err)
		return nil, err
	}
	return mq, nil
}
